package com.tjf.myjetpackdemo.RxObserverModel;

/**
 * @author: tjf
 * @date: 2023-06-07
 * @desc： 装饰器模式  关关联抽象被观察者源
 */
public abstract class AbstractObservableWithUpstream<T, R> extends Observable<R> {

    protected final ObservableSource<T> source;

    protected AbstractObservableWithUpstream(ObservableSource<T> source) {
        this.source = source;
    }

    @Override
    protected void subscribeActual(Observer<R> observer) {

    }
}
